1054080b24d26ceb7d079a2a8089b062198d4223,spring-messaging/src/main/java/org/springframework/messaging/simp/broker/DefaultSubscriptionRegistry.java,DestinationCache,mapToDestination,#String#SessionSubscriptionInfo#,128

Before Change



		public void mapToDestination(String destination, SessionSubscriptionInfo info) {
			synchronized(this.monitor) {
				Set<SessionSubscriptionInfo> registrations = this.subscriptionsByDestination.get(destination);
				if (registrations == null) {
					registrations = new CopyOnWriteArraySet<SessionSubscriptionInfo>();
					this.subscriptionsByDestination.put(destination, registrations);

After Change



		public void mapToDestination(String destination, String sessionId, String subsId) {
			synchronized(this.monitor) {
				for (String cachedDestination : this.subscriptionsByDestination.keySet()) {
					if (this.pathMatcher.match(destination, cachedDestination)) {
						MultiValueMap<String, String> registrations = this.subscriptionsByDestination.get(cachedDestination);
						if (registrations == null) {
							registrations = new LinkedMultiValueMap<String, String>();